package com.usian.util.simple;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.usian.util.ConnectionUtil;

public class Send {
    public static void main(String[] args) throws Exception {
        //获取到连接以及mq通道
        Connection connection = ConnectionUtil.getConnection();
        //从连接中创建通道，这是完成大部分API的地方。
        Channel channel = connection.createChannel();
        // 声明（创建）队列，必须声明队列才能够发送消息，我们可以把消息发送到队列中。
        channel.queueDeclare("rabbitmq-simple_queue", false, false, false, null);
        // 消息内容
        String message = "simple_queue";
        channel.basicPublish("", "rabbitmq-simple_queue", null, message.getBytes());
        System.out.println(message + "'");

        //关闭通道和连接
        channel.close();
        connection.close();
    }
}
